package com.redis.demo;

import java.util.HashMap;

import com.redis.demo.api.PublishMsg;
import com.redis.demo.utils.RedisUtils;
import com.redis.demo.utils.SerializeUtils;

import redis.clients.jedis.Jedis;

public class Publish implements PublishMsg{
	
	public void send(Message message){
		System.out.println("----send-----" + message);
		Jedis jedis = RedisUtils.getJedis();
		jedis.publish(message.getTopic(),SerializeUtils.serialize2(message));
	}

}
